#include "msg_queue_peer.h"

int main(int argc, char *argv[])
{
    struct msgqueue send_buf;
    send_buf.typekey = 302;
    send_buf.msgtype = 3;
    //这个mtype可以不用，但是必须赋一个不小于0的数
    
    while (1)
    {
        
        gets(send_buf.data);

        if(msg_queue_send("msgqueue", &send_buf, sizeof(send_buf), 0) < 0)
        {
            printf("msg_queue_send error\n");
            return -1;
        }
    }

    return 0;
}